package com.xinqi.xinqidev.publisher.consumer.listener;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.converter.MessageConversionException;
import org.springframework.stereotype.Component;

/**
 * @author xin麒
 * @date 2023/12/1 23:11
 */
@Component
@Slf4j
public class MqListener {

    //这个不会将消息删除
/*
    @RabbitListener(queues = "simple.queue")
    public void listenSimpleQueue(String msg){
        log.debug(msg + " is SimpleQueue message ......");
        throw new RuntimeException("不小心故意的");
    }
*/
    /**
     * D:\start_java\java_beginning\bin\java.exe -XX:TieredStopAtLevel=1 -noverify -Dspring.output.ansi.enabled=always -Dcom.sun.management.jmxremote -Dspring.jmx.enabled=true -Dspring.liveBeansView.mbeanDomain -Dspring.application.admin.enabled=true -javaagent:D:\start_java\javaidea\IntelliJ_IDEA_2020_2_2\lib\idea_rt.jar=60094:D:\start_java\javaidea\IntelliJ_IDEA_2020_2_2\bin -Dfile.encoding=UTF-8 -classpath D:\start_java\java_beginning\jre\lib\charsets.jar;D:\start_java\java_beginning\jre\lib\deploy.jar;D:\start_java\java_beginning\jre\lib\ext\access-bridge-64.jar;D:\start_java\java_beginning\jre\lib\ext\cldrdata.jar;D:\start_java\java_beginning\jre\lib\ext\dnsns.jar;D:\start_java\java_beginning\jre\lib\ext\jaccess.jar;D:\start_java\java_beginning\jre\lib\ext\jfxrt.jar;D:\start_java\java_beginning\jre\lib\ext\localedata.jar;D:\start_java\java_beginning\jre\lib\ext\nashorn.jar;D:\start_java\java_beginning\jre\lib\ext\sunec.jar;D:\start_java\java_beginning\jre\lib\ext\sunjce_provider.jar;D:\start_java\java_beginning\jre\lib\ext\sunmscapi.jar;D:\start_java\java_beginning\jre\lib\ext\sunpkcs11.jar;D:\start_java\java_beginning\jre\lib\ext\zipfs.jar;D:\start_java\java_beginning\jre\lib\javaws.jar;D:\start_java\java_beginning\jre\lib\jce.jar;D:\start_java\java_beginning\jre\lib\jfr.jar;D:\start_java\java_beginning\jre\lib\jfxswt.jar;D:\start_java\java_beginning\jre\lib\jsse.jar;D:\start_java\java_beginning\jre\lib\management-agent.jar;D:\start_java\java_beginning\jre\lib\plugin.jar;D:\start_java\java_beginning\jre\lib\resources.jar;D:\start_java\java_beginning\jre\lib\rt.jar;D:\start_java\XinQiUtilsOrDemo\rabbitmq\Senior\ErrorStrategy-RepublishMessageRecoverer-no9\consumer\target\classes;D:\maven-repo\org\projectlombok\lombok\1.18.26\lombok-1.18.26.jar;D:\maven-repo\org\springframework\boot\spring-boot-starter-amqp\2.7.12\spring-boot-starter-amqp-2.7.12.jar;D:\maven-repo\org\springframework\boot\spring-boot-starter\2.7.12\spring-boot-starter-2.7.12.jar;D:\maven-repo\org\springframework\boot\spring-boot\2.7.12\spring-boot-2.7.12.jar;D:\maven-repo\org\springframework\boot\spring-boot-autoconfigure\2.7.12\spring-boot-autoconfigure-2.7.12.jar;D:\maven-repo\jakarta\annotation\jakarta.annotation-api\1.3.5\jakarta.annotation-api-1.3.5.jar;D:\maven-repo\org\yaml\snakeyaml\1.30\snakeyaml-1.30.jar;D:\maven-repo\org\springframework\spring-messaging\5.3.27\spring-messaging-5.3.27.jar;D:\maven-repo\org\springframework\spring-beans\5.3.27\spring-beans-5.3.27.jar;D:\maven-repo\org\springframework\amqp\spring-rabbit\2.4.12\spring-rabbit-2.4.12.jar;D:\maven-repo\org\springframework\amqp\spring-amqp\2.4.12\spring-amqp-2.4.12.jar;D:\maven-repo\org\springframework\retry\spring-retry\1.3.4\spring-retry-1.3.4.jar;D:\maven-repo\com\rabbitmq\amqp-client\5.14.2\amqp-client-5.14.2.jar;D:\maven-repo\org\springframework\spring-context\5.3.27\spring-context-5.3.27.jar;D:\maven-repo\org\springframework\spring-aop\5.3.27\spring-aop-5.3.27.jar;D:\maven-repo\org\springframework\spring-expression\5.3.27\spring-expression-5.3.27.jar;D:\maven-repo\org\springframework\spring-tx\5.3.27\spring-tx-5.3.27.jar;D:\maven-repo\org\springframework\boot\spring-boot-starter-test\2.7.12\spring-boot-starter-test-2.7.12.jar;D:\maven-repo\org\springframework\boot\spring-boot-test\2.7.12\spring-boot-test-2.7.12.jar;D:\maven-repo\org\springframework\boot\spring-boot-test-autoconfigure\2.7.12\spring-boot-test-autoconfigure-2.7.12.jar;D:\maven-repo\com\jayway\jsonpath\json-path\2.7.0\json-path-2.7.0.jar;D:\maven-repo\net\minidev\json-smart\2.4.11\json-smart-2.4.11.jar;D:\maven-repo\net\minidev\accessors-smart\2.4.11\accessors-smart-2.4.11.jar;D:\maven-repo\org\ow2\asm\asm\9.3\asm-9.3.jar;D:\maven-repo\org\slf4j\slf4j-api\1.7.36\slf4j-api-1.7.36.jar;D:\maven-repo\jakarta\xml\bind\jakarta.xml.bind-api\2.3.3\jakarta.xml.bind-api-2.3.3.jar;D:\maven-repo\jakarta\activation\jakarta.activation-api\1.2.2\jakarta.activation-api-1.2.2.jar;D:\maven-repo\org\assertj\assertj-core\3.22.0\assertj-core-3.22.0.jar;D:\maven-repo\org\hamcrest\hamcrest\2.2\hamcrest-2.2.jar;D:\maven-repo\org\junit\jupiter\junit-jupiter\5.8.2\junit-jupiter-5.8.2.jar;D:\maven-repo\org\junit\jupiter\junit-jupiter-api\5.8.2\junit-jupiter-api-5.8.2.jar;D:\maven-repo\org\opentest4j\opentest4j\1.2.0\opentest4j-1.2.0.jar;D:\maven-repo\org\junit\platform\junit-platform-commons\1.8.2\junit-platform-commons-1.8.2.jar;D:\maven-repo\org\apiguardian\apiguardian-api\1.1.2\apiguardian-api-1.1.2.jar;D:\maven-repo\org\junit\jupiter\junit-jupiter-params\5.8.2\junit-jupiter-params-5.8.2.jar;D:\maven-repo\org\junit\jupiter\junit-jupiter-engine\5.8.2\junit-jupiter-engine-5.8.2.jar;D:\maven-repo\org\junit\platform\junit-platform-engine\1.8.2\junit-platform-engine-1.8.2.jar;D:\maven-repo\org\mockito\mockito-core\4.5.1\mockito-core-4.5.1.jar;D:\maven-repo\net\bytebuddy\byte-buddy\1.12.23\byte-buddy-1.12.23.jar;D:\maven-repo\net\bytebuddy\byte-buddy-agent\1.12.23\byte-buddy-agent-1.12.23.jar;D:\maven-repo\org\objenesis\objenesis\3.2\objenesis-3.2.jar;D:\maven-repo\org\mockito\mockito-junit-jupiter\4.5.1\mockito-junit-jupiter-4.5.1.jar;D:\maven-repo\org\skyscreamer\jsonassert\1.5.1\jsonassert-1.5.1.jar;D:\maven-repo\com\vaadin\external\google\android-json\0.0.20131108.vaadin1\android-json-0.0.20131108.vaadin1.jar;D:\maven-repo\org\springframework\spring-core\5.3.27\spring-core-5.3.27.jar;D:\maven-repo\org\springframework\spring-jcl\5.3.27\spring-jcl-5.3.27.jar;D:\maven-repo\org\springframework\spring-test\5.3.27\spring-test-5.3.27.jar;D:\maven-repo\org\xmlunit\xmlunit-core\2.9.1\xmlunit-core-2.9.1.jar;D:\maven-repo\com\fasterxml\jackson\dataformat\jackson-dataformat-xml\2.13.5\jackson-dataformat-xml-2.13.5.jar;D:\maven-repo\com\fasterxml\jackson\core\jackson-core\2.13.5\jackson-core-2.13.5.jar;D:\maven-repo\com\fasterxml\jackson\core\jackson-annotations\2.13.5\jackson-annotations-2.13.5.jar;D:\maven-repo\com\fasterxml\jackson\core\jackson-databind\2.13.5\jackson-databind-2.13.5.jar;D:\maven-repo\org\codehaus\woodstox\stax2-api\4.2.1\stax2-api-4.2.1.jar;D:\maven-repo\com\fasterxml\woodstox\woodstox-core\6.4.0\woodstox-core-6.4.0.jar;D:\maven-repo\org\springframework\boot\spring-boot-starter-logging\2.7.12\spring-boot-starter-logging-2.7.12.jar;D:\maven-repo\ch\qos\logback\logback-classic\1.2.12\logback-classic-1.2.12.jar;D:\maven-repo\ch\qos\logback\logback-core\1.2.12\logback-core-1.2.12.jar;D:\maven-repo\org\apache\logging\log4j\log4j-to-slf4j\2.17.2\log4j-to-slf4j-2.17.2.jar;D:\maven-repo\org\apache\logging\log4j\log4j-api\2.17.2\log4j-api-2.17.2.jar;D:\maven-repo\org\slf4j\jul-to-slf4j\1.7.36\jul-to-slf4j-1.7.36.jar com.xinqi.xinqidev.publisher.consumer.ConsumerApplication
     *
     *   .   ____          _            __ _ _
     *  /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
     * ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
     *  \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
     *   '  |____| .__|_| |_|_| |_\__, | / / / /
     *  =========|_|==============|___/=/_/_/_/
     *  :: Spring Boot ::               (v2.7.12)
     *
     * 12-02 12:06:17:935  INFO 9432 --- [           main] c.x.x.p.consumer.ConsumerApplication     : Starting ConsumerApplication using Java 1.8.0_311 on LAPTOP-GAHM48A0 with PID 9432 (D:\start_java\XinQiUtilsOrDemo\rabbitmq\Senior\ErrorStrategy-RepublishMessageRecoverer-no9\consumer\target\classes started by 86189 in D:\start_java\XinQiUtilsOrDemo\rabbitmq\Senior\ErrorStrategy-RepublishMessageRecoverer-no9)
     * 12-02 12:06:17:939 DEBUG 9432 --- [           main] c.x.x.p.consumer.ConsumerApplication     : Running with Spring Boot v2.7.12, Spring v5.3.27
     * 12-02 12:06:17:940  INFO 9432 --- [           main] c.x.x.p.consumer.ConsumerApplication     : No active profile set, falling back to 1 default profile: "default"
     * 12-02 12:06:18:967 DEBUG 9432 --- [           main] c.x.x.p.c.config.ErrorConfiguration      : 加载RepublishMessageRecoverer
     * 12-02 12:06:19:126  INFO 9432 --- [           main] o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: [192.168.10.100:5672]
     * 12-02 12:06:19:152  INFO 9432 --- [           main] o.s.a.r.c.CachingConnectionFactory       : Created new connection: rabbitConnectionFactory#3aa3193a:0/SimpleConnection@4604b900 [delegate=amqp://xinqiyaya@192.168.10.100:5672//xinqiyayaya, localPort= 60103]
     * 12-02 12:06:19:199  INFO 9432 --- [           main] c.x.x.p.consumer.ConsumerApplication     : Started ConsumerApplication in 1.754 seconds (JVM running for 2.707)
     * 12-02 12:06:23:280 DEBUG 9432 --- [ntContainer#0-1] c.x.x.p.consumer.listener.MqListener     : xas2 is SimpleQueue message ......
     * 12-02 12:06:24:284 DEBUG 9432 --- [ntContainer#0-1] c.x.x.p.consumer.listener.MqListener     : xas2 is SimpleQueue message ......
     * 12-02 12:06:25:286 DEBUG 9432 --- [ntContainer#0-1] c.x.x.p.consumer.listener.MqListener     : xas2 is SimpleQueue message ......
     * 12-02 12:06:25:296  WARN 9432 --- [ntContainer#0-1] o.s.a.r.retry.RepublishMessageRecoverer  : Republishing failed message to exchange 'error.direct' with routing key error
     */

    //这个会将消息删除
    @RabbitListener(queues = "simple.queue")
    public void listenSimpleQueue(String msg){
        log.debug(msg + " is SimpleQueue message ......");
        throw new MessageConversionException("故意的");
    }
/**
 * D:\start_java\java_beginning\bin\java.exe -XX:TieredStopAtLevel=1 -noverify -Dspring.output.ansi.enabled=always -Dcom.sun.management.jmxremote -Dspring.jmx.enabled=true -Dspring.liveBeansView.mbeanDomain -Dspring.application.admin.enabled=true -javaagent:D:\start_java\javaidea\IntelliJ_IDEA_2020_2_2\lib\idea_rt.jar=60010:D:\start_java\javaidea\IntelliJ_IDEA_2020_2_2\bin -Dfile.encoding=UTF-8 -classpath D:\start_java\java_beginning\jre\lib\charsets.jar;D:\start_java\java_beginning\jre\lib\deploy.jar;D:\start_java\java_beginning\jre\lib\ext\access-bridge-64.jar;D:\start_java\java_beginning\jre\lib\ext\cldrdata.jar;D:\start_java\java_beginning\jre\lib\ext\dnsns.jar;D:\start_java\java_beginning\jre\lib\ext\jaccess.jar;D:\start_java\java_beginning\jre\lib\ext\jfxrt.jar;D:\start_java\java_beginning\jre\lib\ext\localedata.jar;D:\start_java\java_beginning\jre\lib\ext\nashorn.jar;D:\start_java\java_beginning\jre\lib\ext\sunec.jar;D:\start_java\java_beginning\jre\lib\ext\sunjce_provider.jar;D:\start_java\java_beginning\jre\lib\ext\sunmscapi.jar;D:\start_java\java_beginning\jre\lib\ext\sunpkcs11.jar;D:\start_java\java_beginning\jre\lib\ext\zipfs.jar;D:\start_java\java_beginning\jre\lib\javaws.jar;D:\start_java\java_beginning\jre\lib\jce.jar;D:\start_java\java_beginning\jre\lib\jfr.jar;D:\start_java\java_beginning\jre\lib\jfxswt.jar;D:\start_java\java_beginning\jre\lib\jsse.jar;D:\start_java\java_beginning\jre\lib\management-agent.jar;D:\start_java\java_beginning\jre\lib\plugin.jar;D:\start_java\java_beginning\jre\lib\resources.jar;D:\start_java\java_beginning\jre\lib\rt.jar;D:\start_java\XinQiUtilsOrDemo\rabbitmq\Senior\ErrorStrategy-RepublishMessageRecoverer-no9\consumer\target\classes;D:\maven-repo\org\projectlombok\lombok\1.18.26\lombok-1.18.26.jar;D:\maven-repo\org\springframework\boot\spring-boot-starter-amqp\2.7.12\spring-boot-starter-amqp-2.7.12.jar;D:\maven-repo\org\springframework\boot\spring-boot-starter\2.7.12\spring-boot-starter-2.7.12.jar;D:\maven-repo\org\springframework\boot\spring-boot\2.7.12\spring-boot-2.7.12.jar;D:\maven-repo\org\springframework\boot\spring-boot-autoconfigure\2.7.12\spring-boot-autoconfigure-2.7.12.jar;D:\maven-repo\jakarta\annotation\jakarta.annotation-api\1.3.5\jakarta.annotation-api-1.3.5.jar;D:\maven-repo\org\yaml\snakeyaml\1.30\snakeyaml-1.30.jar;D:\maven-repo\org\springframework\spring-messaging\5.3.27\spring-messaging-5.3.27.jar;D:\maven-repo\org\springframework\spring-beans\5.3.27\spring-beans-5.3.27.jar;D:\maven-repo\org\springframework\amqp\spring-rabbit\2.4.12\spring-rabbit-2.4.12.jar;D:\maven-repo\org\springframework\amqp\spring-amqp\2.4.12\spring-amqp-2.4.12.jar;D:\maven-repo\org\springframework\retry\spring-retry\1.3.4\spring-retry-1.3.4.jar;D:\maven-repo\com\rabbitmq\amqp-client\5.14.2\amqp-client-5.14.2.jar;D:\maven-repo\org\springframework\spring-context\5.3.27\spring-context-5.3.27.jar;D:\maven-repo\org\springframework\spring-aop\5.3.27\spring-aop-5.3.27.jar;D:\maven-repo\org\springframework\spring-expression\5.3.27\spring-expression-5.3.27.jar;D:\maven-repo\org\springframework\spring-tx\5.3.27\spring-tx-5.3.27.jar;D:\maven-repo\org\springframework\boot\spring-boot-starter-test\2.7.12\spring-boot-starter-test-2.7.12.jar;D:\maven-repo\org\springframework\boot\spring-boot-test\2.7.12\spring-boot-test-2.7.12.jar;D:\maven-repo\org\springframework\boot\spring-boot-test-autoconfigure\2.7.12\spring-boot-test-autoconfigure-2.7.12.jar;D:\maven-repo\com\jayway\jsonpath\json-path\2.7.0\json-path-2.7.0.jar;D:\maven-repo\net\minidev\json-smart\2.4.11\json-smart-2.4.11.jar;D:\maven-repo\net\minidev\accessors-smart\2.4.11\accessors-smart-2.4.11.jar;D:\maven-repo\org\ow2\asm\asm\9.3\asm-9.3.jar;D:\maven-repo\org\slf4j\slf4j-api\1.7.36\slf4j-api-1.7.36.jar;D:\maven-repo\jakarta\xml\bind\jakarta.xml.bind-api\2.3.3\jakarta.xml.bind-api-2.3.3.jar;D:\maven-repo\jakarta\activation\jakarta.activation-api\1.2.2\jakarta.activation-api-1.2.2.jar;D:\maven-repo\org\assertj\assertj-core\3.22.0\assertj-core-3.22.0.jar;D:\maven-repo\org\hamcrest\hamcrest\2.2\hamcrest-2.2.jar;D:\maven-repo\org\junit\jupiter\junit-jupiter\5.8.2\junit-jupiter-5.8.2.jar;D:\maven-repo\org\junit\jupiter\junit-jupiter-api\5.8.2\junit-jupiter-api-5.8.2.jar;D:\maven-repo\org\opentest4j\opentest4j\1.2.0\opentest4j-1.2.0.jar;D:\maven-repo\org\junit\platform\junit-platform-commons\1.8.2\junit-platform-commons-1.8.2.jar;D:\maven-repo\org\apiguardian\apiguardian-api\1.1.2\apiguardian-api-1.1.2.jar;D:\maven-repo\org\junit\jupiter\junit-jupiter-params\5.8.2\junit-jupiter-params-5.8.2.jar;D:\maven-repo\org\junit\jupiter\junit-jupiter-engine\5.8.2\junit-jupiter-engine-5.8.2.jar;D:\maven-repo\org\junit\platform\junit-platform-engine\1.8.2\junit-platform-engine-1.8.2.jar;D:\maven-repo\org\mockito\mockito-core\4.5.1\mockito-core-4.5.1.jar;D:\maven-repo\net\bytebuddy\byte-buddy\1.12.23\byte-buddy-1.12.23.jar;D:\maven-repo\net\bytebuddy\byte-buddy-agent\1.12.23\byte-buddy-agent-1.12.23.jar;D:\maven-repo\org\objenesis\objenesis\3.2\objenesis-3.2.jar;D:\maven-repo\org\mockito\mockito-junit-jupiter\4.5.1\mockito-junit-jupiter-4.5.1.jar;D:\maven-repo\org\skyscreamer\jsonassert\1.5.1\jsonassert-1.5.1.jar;D:\maven-repo\com\vaadin\external\google\android-json\0.0.20131108.vaadin1\android-json-0.0.20131108.vaadin1.jar;D:\maven-repo\org\springframework\spring-core\5.3.27\spring-core-5.3.27.jar;D:\maven-repo\org\springframework\spring-jcl\5.3.27\spring-jcl-5.3.27.jar;D:\maven-repo\org\springframework\spring-test\5.3.27\spring-test-5.3.27.jar;D:\maven-repo\org\xmlunit\xmlunit-core\2.9.1\xmlunit-core-2.9.1.jar;D:\maven-repo\com\fasterxml\jackson\dataformat\jackson-dataformat-xml\2.13.5\jackson-dataformat-xml-2.13.5.jar;D:\maven-repo\com\fasterxml\jackson\core\jackson-core\2.13.5\jackson-core-2.13.5.jar;D:\maven-repo\com\fasterxml\jackson\core\jackson-annotations\2.13.5\jackson-annotations-2.13.5.jar;D:\maven-repo\com\fasterxml\jackson\core\jackson-databind\2.13.5\jackson-databind-2.13.5.jar;D:\maven-repo\org\codehaus\woodstox\stax2-api\4.2.1\stax2-api-4.2.1.jar;D:\maven-repo\com\fasterxml\woodstox\woodstox-core\6.4.0\woodstox-core-6.4.0.jar;D:\maven-repo\org\springframework\boot\spring-boot-starter-logging\2.7.12\spring-boot-starter-logging-2.7.12.jar;D:\maven-repo\ch\qos\logback\logback-classic\1.2.12\logback-classic-1.2.12.jar;D:\maven-repo\ch\qos\logback\logback-core\1.2.12\logback-core-1.2.12.jar;D:\maven-repo\org\apache\logging\log4j\log4j-to-slf4j\2.17.2\log4j-to-slf4j-2.17.2.jar;D:\maven-repo\org\apache\logging\log4j\log4j-api\2.17.2\log4j-api-2.17.2.jar;D:\maven-repo\org\slf4j\jul-to-slf4j\1.7.36\jul-to-slf4j-1.7.36.jar com.xinqi.xinqidev.publisher.consumer.ConsumerApplication
 *
 *   .   ____          _            __ _ _
 *  /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
 * ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 *  \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
 *   '  |____| .__|_| |_|_| |_\__, | / / / /
 *  =========|_|==============|___/=/_/_/_/
 *  :: Spring Boot ::               (v2.7.12)
 *
 * 12-02 12:05:16:935  INFO 9736 --- [           main] c.x.x.p.consumer.ConsumerApplication     : Starting ConsumerApplication using Java 1.8.0_311 on LAPTOP-GAHM48A0 with PID 9736 (D:\start_java\XinQiUtilsOrDemo\rabbitmq\Senior\ErrorStrategy-RepublishMessageRecoverer-no9\consumer\target\classes started by 86189 in D:\start_java\XinQiUtilsOrDemo\rabbitmq\Senior\ErrorStrategy-RepublishMessageRecoverer-no9)
 * 12-02 12:05:16:939 DEBUG 9736 --- [           main] c.x.x.p.consumer.ConsumerApplication     : Running with Spring Boot v2.7.12, Spring v5.3.27
 * 12-02 12:05:16:940  INFO 9736 --- [           main] c.x.x.p.consumer.ConsumerApplication     : No active profile set, falling back to 1 default profile: "default"
 * 12-02 12:05:18:130 DEBUG 9736 --- [           main] c.x.x.p.c.config.ErrorConfiguration      : 加载RepublishMessageRecoverer
 * 12-02 12:05:18:294  INFO 9736 --- [           main] o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: [192.168.10.100:5672]
 * 12-02 12:05:18:319  INFO 9736 --- [           main] o.s.a.r.c.CachingConnectionFactory       : Created new connection: rabbitConnectionFactory#3aa3193a:0/SimpleConnection@4604b900 [delegate=amqp://xinqiyaya@192.168.10.100:5672//xinqiyayaya, localPort= 60023]
 * 12-02 12:05:18:373  INFO 9736 --- [           main] c.x.x.p.consumer.ConsumerApplication     : Started ConsumerApplication in 1.892 seconds (JVM running for 2.992)
 * 12-02 12:05:24:904 DEBUG 9736 --- [ntContainer#0-1] c.x.x.p.consumer.listener.MqListener     : swq is SimpleQueue message ......
 * 12-02 12:05:25:906 DEBUG 9736 --- [ntContainer#0-1] c.x.x.p.consumer.listener.MqListener     : swq is SimpleQueue message ......
 * 12-02 12:05:26:907 DEBUG 9736 --- [ntContainer#0-1] c.x.x.p.consumer.listener.MqListener     : swq is SimpleQueue message ......
 * 12-02 12:05:26:914  WARN 9736 --- [ntContainer#0-1] o.s.a.r.retry.RepublishMessageRecoverer  : Republishing failed message to exchange 'error.direct' with routing key error
 */

}
